package jobs;

import java.io.IOException;

import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;

import domain.Tweet;
import domain.User;


public class TweetInputFormat extends FileInputFormat<User, Tweet>{

	@Override
	public RecordReader<User, Tweet> createRecordReader(InputSplit arg0,
			TaskAttemptContext arg1) throws IOException, InterruptedException {
		return new TweetRecordReader(arg0,arg1);
	}

	
}
